//package net.reactor;
//
//import reactor.core.publisher.Flux;
//import reactor.core.scheduler.Schedulers;
//
///**
// * @author 王霄
// * @date 2021/10/2 11:22
// */
//public class Reactor02 {
//    public static void main(String[] args) throws InterruptedException {
//        Flux.range(1, 100).
//                parallel(10)
//                .runOn(Schedulers.boundedElastic())
//                .subscribe(i -> {
//                    try {
//                        Thread.sleep(1000);
//                    } catch (InterruptedException e) {
//                        e.printStackTrace();
//                    }
//                    System.out.println(Thread.currentThread().getName() + "  " + i);
//                });
//        Thread.sleep(100000000);
//    }
//}
